Class StreamSubscriptionTimeoutSettings
Leaked publishers and subscribers are cleaned up when they are not used within a given deadline, configured by StreamSubscriptionTimeoutSettings.
Implements
Inherited Members
Namespace: Akka.Streams
Assembly: Akka.Streams.dll
Syntax
public sealed class StreamSubscriptionTimeoutSettings : IEquatable<StreamSubscriptionTimeoutSettings>
Constructors
| Edit this page View SourceStreamSubscriptionTimeoutSettings(StreamSubscriptionTimeoutTerminationMode, TimeSpan)
TBD
Declaration
public StreamSubscriptionTimeoutSettings(StreamSubscriptionTimeoutTerminationMode mode, TimeSpan timeout)
Parameters
| Type | Name | Description |
|---|---|---|
| StreamSubscriptionTimeoutTerminationMode | mode | TBD |
| TimeSpan | timeout | TBD |
Fields
| Edit this page View SourceMode
TBD
Declaration
public readonly StreamSubscriptionTimeoutTerminationMode Mode
Field Value
| Type | Description |
|---|---|
| StreamSubscriptionTimeoutTerminationMode |
Timeout
TBD
Declaration
public readonly TimeSpan Timeout
Field Value
| Type | Description |
|---|---|
| TimeSpan |
Methods
| Edit this page View SourceCreate(Config)
TBD
Declaration
public static StreamSubscriptionTimeoutSettings Create(Config config)
Parameters
| Type | Name | Description |
|---|---|---|
| Config | config | TBD |
Returns
| Type | Description |
|---|---|
| StreamSubscriptionTimeoutSettings | TBD |
Exceptions
| Type | Condition |
|---|---|
| ArgumentException | TBD |
Equals(StreamSubscriptionTimeoutSettings)
Indicates whether the current object is equal to another object of the same type.
Declaration
public bool Equals(StreamSubscriptionTimeoutSettings other)
Parameters
| Type | Name | Description |
|---|---|---|
| StreamSubscriptionTimeoutSettings | other | An object to compare with this object. |
Returns
| Type | Description |
|---|---|
| bool | true if the current object is equal to the |
Equals(object)
Determines whether the specified object is equal to the current object.
Declaration
public override bool Equals(object obj)
Parameters
| Type | Name | Description |
|---|---|---|
| object | obj | The object to compare with the current object. |
Returns
| Type | Description |
|---|---|
| bool | true if the specified object is equal to the current object; otherwise, false. |
Overrides
| Edit this page View SourceGetHashCode()
Serves as the default hash function.
Declaration
public override int GetHashCode()
Returns
| Type | Description |
|---|---|
| int | A hash code for the current object. |
Overrides
| Edit this page View SourceToString()
Returns a string that represents the current object.
Declaration
public override string ToString()
Returns
| Type | Description |
|---|---|
| string | A string that represents the current object. |
Edit this page