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