Class SimpleOutputs

TBD

Inheritance

object

SimpleOutputs

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Streams.Implementation

Assembly: Akka.Streams.dll

Syntax

public class SimpleOutputs

Constructors

SimpleOutputs(IActorRef, IPump)

TBD

Declaration

public SimpleOutputs(IActorRef actor, IPump pump)

Parameters

Type	Name	Description
IActorRef	actor	TBD
IPump	pump	TBD

Fields

Actor

TBD

Declaration

public readonly IActorRef Actor

Field Value

Type	Description
IActorRef

DownstreamDemand

TBD

Declaration

protected long DownstreamDemand

Field Value

Type	Description
long

ExposedPublisher

TBD

Declaration

protected IActorPublisher ExposedPublisher

Field Value

Type	Description
IActorPublisher

IsDownstreamCompleted

TBD

Declaration

protected bool IsDownstreamCompleted

Field Value

Type	Description
bool

Pump

TBD

Declaration

public readonly IPump Pump

Field Value

Type	Description
IPump

Subscriber

TBD

Declaration

protected IUntypedSubscriber Subscriber

Field Value

Type	Description
IUntypedSubscriber

Properties

DemandCount

TBD

Declaration

public long DemandCount { get; }

Property Value

Type	Description
long

IsClosed

TBD

Declaration

public bool IsClosed { get; }

Property Value

Type	Description
bool

IsDemandAvailable

TBD

Declaration

public bool IsDemandAvailable { get; }

Property Value

Type	Description
bool

IsOpen

TBD

Declaration

public bool IsOpen { get; }

Property Value

Type	Description
bool

IsSubscribed

TBD

Declaration

public bool IsSubscribed { get; }

Property Value

Type	Description
bool

NeedsDemand

TBD

Declaration

public TransferState NeedsDemand { get; }

Property Value

Type	Description
TransferState

NeedsDemandOrCancel

TBD

Declaration

public TransferState NeedsDemandOrCancel { get; }

Property Value

Type	Description
TransferState

SubReceive

TBD

Declaration

public virtual SubReceive SubReceive { get; }

Property Value

Type	Description
SubReceive

Methods

Cancel()

TBD

Declaration

public virtual void Cancel()

Complete()

TBD

Declaration

public virtual void Complete()

CreateSubscription()

TBD

Declaration

protected ISubscription CreateSubscription()

Returns

Type	Description
ISubscription	TBD

DownstreamRunning(object)

TBD

Declaration

protected bool DownstreamRunning(object message)

Parameters

Type	Name	Description
object	message	TBD

Returns

Type	Description
bool	TBD

EnqueueOutputElement(object)

TBD

Declaration

public void EnqueueOutputElement(object element)

Parameters

Type	Name	Description
object	element	TBD

Error(Exception)

TBD

Declaration

public virtual void Error(Exception e)

Parameters

Type	Name	Description
Exception	e	TBD

WaitingExposedPublisher(object)

TBD

Declaration

protected bool WaitingExposedPublisher(object message)

Parameters

Type	Name	Description
object	message	TBD

Returns

Type	Description
bool	TBD

Exceptions

Type	Condition
IllegalStateException	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)