ChannelSendOperator(source: Publisher<out T>, writeFunction: Function<Publisher<T>, Publisher<Void>>)