code: def test_sink_with_args_and_kwargs():
      L = dict()
  
      def mycustomsink(elem, key, prefix=""):
          key = prefix + key
          if key not in L:
              L[key] = list()
          L[key].append(elem)
  
      s = Stream()
      sink = s.sink(mycustomsink, "cat", "super", stream_name="test")
      s.emit(1)
      s.emit(2)
  
      assert L["supercat"] == [1, 2]
      assert sink.name == "test"
  
file_path: streamz/streamz/tests/test_sinks.py
imports: import weakref
  import pytest
  from streamz import Stream
  from streamz.sinks import _global_sinks, Sink
  from streamz.utils_test import tmpfile, wait_for
label_desc: Use image node_id 1 for calling a global function with example usage: test_sink_with_args_and_kwargs() without return types