Interface IPump
TBD
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public interface IPump
Properties
| Edit this page View SourceCurrentAction
TBD
Declaration
Action CurrentAction { get; set; }
Property Value
Type | Description |
---|---|
Action |
IsPumpFinished
TBD
Declaration
bool IsPumpFinished { get; }
Property Value
Type | Description |
---|---|
bool |
TransferState
TBD
Declaration
TransferState TransferState { get; set; }
Property Value
Type | Description |
---|---|
TransferState |
Methods
| Edit this page View SourceGotUpstreamSubscription()
TBD
Declaration
void GotUpstreamSubscription()
InitialPhase(int, TransferPhase)
TBD
Declaration
void InitialPhase(int waitForUpstream, TransferPhase andThen)
Parameters
Type | Name | Description |
---|---|---|
int | waitForUpstream | TBD |
TransferPhase | andThen | TBD |
NextPhase(TransferPhase)
TBD
Declaration
void NextPhase(TransferPhase phase)
Parameters
Type | Name | Description |
---|---|---|
TransferPhase | phase | TBD |
Pump()
TBD
Declaration
void Pump()
PumpFailed(Exception)
TBD
Declaration
void PumpFailed(Exception e)
Parameters
Type | Name | Description |
---|---|---|
Exception | e | TBD |
PumpFinished()
TBD
Declaration
void PumpFinished()
WaitForUpstream(int)
TBD
Declaration
void WaitForUpstream(int waitForUpstream)
Parameters
Type | Name | Description |
---|---|---|
int | waitForUpstream | TBD |