Class ReceiveTransportObservable
- Namespace
- MassTransit.Observables
- Assembly
- MassTransit.Abstractions.dll
public class ReceiveTransportObservable : Connectable<IReceiveTransportObserver>, IReceiveTransportObserver
- Inheritance
-
ReceiveTransportObservable
- Implements
- Inherited Members
Constructors
ReceiveTransportObservable()
public ReceiveTransportObservable()
Methods
Completed(ReceiveTransportCompleted)
Called when the receive endpoint has completed
public Task Completed(ReceiveTransportCompleted completed)
Parameters
completedReceiveTransportCompleted
Returns
Faulted(ReceiveTransportFaulted)
Called when the receive endpoint faults
public Task Faulted(ReceiveTransportFaulted faulted)
Parameters
faultedReceiveTransportFaulted
Returns
Ready(ReceiveTransportReady)
Called when the receive endpoint is ready to receive messages
public Task Ready(ReceiveTransportReady ready)
Parameters
readyReceiveTransportReady