org.gecko.core.pushstream.distributed.DistributedEventSourceTest.testExampleSimple
orig stream on close
orig stream error return channel error