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

| Improve this Doc View Source

SimpleOutputs(IActorRef, IPump)

TBD

Declaration

public SimpleOutputs(IActorRef actor, IPump pump)

Parameters

Type	Name	Description
IActorRef	actor	TBD
IPump	pump	TBD

Fields

| Improve this Doc View Source

Actor

TBD

Declaration

public readonly IActorRef Actor

Field Value

Type	Description
IActorRef

| Improve this Doc View Source

DownstreamDemand

TBD

Declaration

protected long DownstreamDemand

Field Value

Type	Description
Int64

| Improve this Doc View Source

ExposedPublisher

TBD

Declaration

protected IActorPublisher ExposedPublisher

Field Value

Type	Description
IActorPublisher

| Improve this Doc View Source

IsDownstreamCompleted

TBD

Declaration

protected bool IsDownstreamCompleted

Field Value

Type	Description
Boolean

| Improve this Doc View Source

Pump

TBD

Declaration

public readonly IPump Pump

Field Value

Type	Description
IPump

| Improve this Doc View Source

Subscriber

TBD

Declaration

protected IUntypedSubscriber Subscriber

Field Value

Type	Description
IUntypedSubscriber

Properties

| Improve this Doc View Source

DemandCount

TBD

Declaration

public long DemandCount { get; }

Property Value

Type	Description
Int64

| Improve this Doc View Source

IsClosed

TBD

Declaration

public bool IsClosed { get; }

Property Value

Type	Description
Boolean

| Improve this Doc View Source

IsDemandAvailable

TBD

Declaration

public bool IsDemandAvailable { get; }

Property Value

Type	Description
Boolean

| Improve this Doc View Source

IsOpen

TBD

Declaration

public bool IsOpen { get; }

Property Value

Type	Description
Boolean

| Improve this Doc View Source

IsSubscribed

TBD

Declaration

public bool IsSubscribed { get; }

Property Value

Type	Description
Boolean

| Improve this Doc View Source

NeedsDemand

TBD

Declaration

public TransferState NeedsDemand { get; }

Property Value

Type	Description
TransferState

| Improve this Doc View Source

NeedsDemandOrCancel

TBD

Declaration

public TransferState NeedsDemandOrCancel { get; }

Property Value

Type	Description
TransferState

| Improve this Doc View Source

SubReceive

TBD

Declaration

public virtual SubReceive SubReceive { get; }

Property Value

Type	Description
SubReceive

Methods

| Improve this Doc View Source

Cancel()

TBD

Declaration

public virtual void Cancel()

| Improve this Doc View Source

Complete()

TBD

Declaration

public virtual void Complete()

| Improve this Doc View Source

CreateSubscription()

TBD

Declaration

protected ISubscription CreateSubscription()

Returns

Type	Description
Reactive.Streams.ISubscription	TBD

| Improve this Doc View Source

DownstreamRunning(Object)

TBD

Declaration

protected bool DownstreamRunning(object message)

Parameters

Type	Name	Description
Object	message	TBD

Returns

Type	Description
Boolean	TBD

| Improve this Doc View Source

EnqueueOutputElement(Object)

TBD

Declaration

public void EnqueueOutputElement(object element)

Parameters

Type	Name	Description
Object	element	TBD

| Improve this Doc View Source

Error(Exception)

TBD

Declaration

public virtual void Error(Exception e)

Parameters

Type	Name	Description
Exception	e	TBD

| Improve this Doc View Source

WaitingExposedPublisher(Object)

TBD

Declaration

protected bool WaitingExposedPublisher(object message)

Parameters

Type	Name	Description
Object	message	TBD

Returns

Type	Description
Boolean	TBD

Exceptions

Type	Condition
IllegalStateException	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)