Class ReactiveStreamsCompliance

TBD

Inheritance

Object

ReactiveStreamsCompliance

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 static class ReactiveStreamsCompliance

Fields

| Improve this Doc View Source

CanNotSubscribeTheSameSubscriberMultipleTimes

TBD

Declaration

public const string CanNotSubscribeTheSameSubscriberMultipleTimes = "can not subscribe the same subscriber multiple times (see reactive-streams specification, rules 1.10 and 2.12)"

Field Value

Type	Description
String

| Improve this Doc View Source

CanNotSubscribeTheSameSubscriberMultipleTimesException

TBD

Declaration

public static readonly Exception CanNotSubscribeTheSameSubscriberMultipleTimesException

Field Value

Type	Description
Exception

| Improve this Doc View Source

ElementMustNotBeNullException

TBD

Declaration

public static readonly Exception ElementMustNotBeNullException

Field Value

Type	Description
Exception

| Improve this Doc View Source

ElementMustNotBeNullMsg

TBD

Declaration

public const string ElementMustNotBeNullMsg = "Element must not be null, rule 2.13"

Field Value

Type	Description
String

| Improve this Doc View Source

ExceptionMustNotBeNullMsg

TBD

Declaration

public const string ExceptionMustNotBeNullMsg = "Exception must not be null, rule 2.13"

Field Value

Type	Description
String

| Improve this Doc View Source

NumberOfElementsInRequestMustBePositiveException

TBD

Declaration

public static readonly Exception NumberOfElementsInRequestMustBePositiveException

Field Value

Type	Description
Exception

| Improve this Doc View Source

NumberOfElementsInRequestMustBePositiveMsg

TBD

Declaration

public const string NumberOfElementsInRequestMustBePositiveMsg = "The number of requested elements must be > 0 (see reactive-streams specification, rule 3.9)"

Field Value

Type	Description
String

| Improve this Doc View Source

SubscriberMustNotBeNullMsg

TBD

Declaration

public const string SubscriberMustNotBeNullMsg = "Subscriber must not be null, rule 1.9"

Field Value

Type	Description
String

| Improve this Doc View Source

SubscriptionMustNotBeNullException

TBD

Declaration

public static readonly Exception SubscriptionMustNotBeNullException

Field Value

Type	Description
Exception

| Improve this Doc View Source

SubscriptionMustNotBeNullMsg

TBD

Declaration

public const string SubscriptionMustNotBeNullMsg = "Subscription must not be null, rule 2.13"

Field Value

Type	Description
String

| Improve this Doc View Source

SupportsOnlyASingleSubscriber

TBD

Declaration

public const string SupportsOnlyASingleSubscriber = "only supports one subscriber (which is allowed, see reactive-streams specification, rule 1.12)"

Field Value

Type	Description
String

Properties

| Improve this Doc View Source

ExceptionMustNotBeNullException

TBD

Declaration

public static Exception ExceptionMustNotBeNullException { get; }

Property Value

Type	Description
Exception

| Improve this Doc View Source

SubscriberMustNotBeNullException

TBD

Declaration

public static Exception SubscriberMustNotBeNullException { get; }

Property Value

Type	Description
Exception

Methods

| Improve this Doc View Source

RejectAdditionalSubscriber<T>(ISubscriber<T>, String)

TBD

Declaration

public static void RejectAdditionalSubscriber<T>(ISubscriber<T> subscriber, string rejector)

Parameters

Type	Name	Description
Reactive.Streams.ISubscriber<T>	subscriber	TBD
String	rejector	TBD

Type Parameters

Name	Description
T	TBD

| Improve this Doc View Source

RejectDueToNonPositiveDemand<T>(ISubscriber<T>)

TBD

Declaration

public static void RejectDueToNonPositiveDemand<T>(ISubscriber<T> subscriber)

Parameters

Type	Name	Description
Reactive.Streams.ISubscriber<T>	subscriber	TBD

Type Parameters

Name	Description
T	TBD

| Improve this Doc View Source

RejectDuplicateSubscriber<T>(ISubscriber<T>)

TBD

Declaration

public static void RejectDuplicateSubscriber<T>(ISubscriber<T> subscriber)

Parameters

Type	Name	Description
Reactive.Streams.ISubscriber<T>	subscriber	TBD

Type Parameters

Name	Description
T	TBD

| Improve this Doc View Source

RequireNonNullElement(Object)

TBD

Declaration

public static void RequireNonNullElement(object element)

Parameters

Type	Name	Description
Object	element	TBD

Exceptions

Type	Condition
ArgumentNullException	This exception is thrown when the specified `element` is undefined.

| Improve this Doc View Source

RequireNonNullException(Exception)

TBD

Declaration

public static void RequireNonNullException(Exception exception)

Parameters

Type	Name	Description
Exception	exception	TBD

Exceptions

Type	Condition
ArgumentNullException	This exception is thrown when the specified `exception` is undefined.

| Improve this Doc View Source

RequireNonNullSubscriber<T>(ISubscriber<T>)

TBD

Declaration

public static void RequireNonNullSubscriber<T>(ISubscriber<T> subscriber)

Parameters

Type	Name	Description
Reactive.Streams.ISubscriber<T>	subscriber	TBD

Type Parameters

Name	Description
T	TBD

| Improve this Doc View Source

RequireNonNullSubscription(ISubscription)

TBD

Declaration

public static void RequireNonNullSubscription(ISubscription subscription)

Parameters

Type	Name	Description
Reactive.Streams.ISubscription	subscription	TBD

Exceptions

Type	Condition
ArgumentNullException	This exception is thrown when the specified `subscription` is undefined.

| Improve this Doc View Source

TryCancel(ISubscription, Exception)

TBD

Declaration

public static void TryCancel(ISubscription subscription, Exception cause)

Parameters

Type	Name	Description
Reactive.Streams.ISubscription	subscription	TBD
Exception	cause	TBD

Exceptions

Type	Condition
SignalThrewException	This exception is thrown when an exception occurs while canceling the specified `subscription`.

| Improve this Doc View Source

TryOnComplete<T>(ISubscriber<T>)

TBD

Declaration

public static void TryOnComplete<T>(ISubscriber<T> subscriber)

Parameters

Type	Name	Description
Reactive.Streams.ISubscriber<T>	subscriber	TBD

Type Parameters

Name	Description
T	TBD

Exceptions

Type	Condition
SignalThrewException	TBD

| Improve this Doc View Source

TryOnError<T>(ISubscriber<T>, Exception)

TBD

Declaration

public static void TryOnError<T>(ISubscriber<T> subscriber, Exception cause)

Parameters

Type	Name	Description
Reactive.Streams.ISubscriber<T>	subscriber	TBD
Exception	cause	TBD

Type Parameters

Name	Description
T	TBD

Exceptions

Type	Condition
IllegalStateException	TBD
SignalThrewException	TBD

| Improve this Doc View Source

TryOnNext<T>(ISubscriber<T>, T)

TBD

Declaration

public static void TryOnNext<T>(ISubscriber<T> subscriber, T element)

Parameters

Type	Name	Description
Reactive.Streams.ISubscriber<T>	subscriber	TBD
T	element	TBD

Type Parameters

Name	Description
T	TBD

Exceptions

Type	Condition
SignalThrewException	TBD

| Improve this Doc View Source

TryOnSubscribe<T>(ISubscriber<T>, ISubscription)

TBD

Declaration

public static void TryOnSubscribe<T>(ISubscriber<T> subscriber, ISubscription subscription)

Parameters

Type	Name	Description
Reactive.Streams.ISubscriber<T>	subscriber	TBD
Reactive.Streams.ISubscription	subscription	TBD

Type Parameters

Name	Description
T	TBD

Exceptions

Type	Condition
SignalThrewException	TBD

| Improve this Doc View Source

TryRequest(ISubscription, Int64)

TBD

Declaration

public static void TryRequest(ISubscription subscription, long demand)

Parameters

Type	Name	Description
Reactive.Streams.ISubscription	subscription	TBD
Int64	demand	TBD

Exceptions

Type	Condition
SignalThrewException	This exception is thrown when an exception occurs while requesting no events be sent to the specified `subscription`.