return Flux.create(sink -> {
FluxSink<String> serialize = sink.serialize();
MessageHandler handler = msg -> serialize.next(String.class.cast(msg.getPayload()));
serialize.setCancellation(() -> filesChannel().unsubscribe(handler));
filesChannel().subscribe(handler);
});
Метод serialize () не определен для типа FluxSink