Class RxJavaStreamsServiceFactory

  • All Implemented Interfaces:
    org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsServiceFactory

    public class RxJavaStreamsServiceFactory
    extends Object
    implements org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsServiceFactory
    • Constructor Detail

      • RxJavaStreamsServiceFactory

        public RxJavaStreamsServiceFactory()
    • Method Detail

      • newInstance

        public org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService newInstance​(org.apache.camel.CamelContext context,
                                                                                                       org.apache.camel.component.reactive.streams.engine.ReactiveStreamsEngineConfiguration configuration)
        Specified by:
        newInstance in interface org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsServiceFactory