package org.jboss.resteasy.reactor;

import javax.ws.rs.client.RxInvoker;

import reactor.core.publisher.Flux;
import reactor.core.publisher.FluxSink;

public interface FluxRxInvoker extends RxInvoker<Flux<?>>
{
   FluxSink.OverflowStrategy getOverflowStrategy();

   void setOverflowStrategy(FluxSink.OverflowStrategy overflowStrategy);
}
