Package akka.stream.impl.streamref
Class StreamRefResolverImpl
- java.lang.Object
-
- akka.stream.impl.streamref.StreamRefResolverImpl
-
- All Implemented Interfaces:
Extension
,StreamRefResolver
public final class StreamRefResolverImpl extends java.lang.Object implements StreamRefResolver
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description StreamRefResolverImpl(ExtendedActorSystem system)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> SinkRef<T>
resolveSinkRef(java.lang.String serializedSinkRef)
Deserialize anSinkRef
in theStreamRefResolver.toSerializationFormat(akka.stream.SourceRef<T>)
.<T> SourceRef<T>
resolveSourceRef(java.lang.String serializedSourceRef)
Deserialize anSourceRef
in theStreamRefResolver.toSerializationFormat(akka.stream.SourceRef<T>)
.<T> java.lang.String
toSerializationFormat(SinkRef<T> ref)
Generate full String representation of theSinkRef
.<T> java.lang.String
toSerializationFormat(SourceRef<T> ref)
-
-
-
Constructor Detail
-
StreamRefResolverImpl
public StreamRefResolverImpl(ExtendedActorSystem system)
-
-
Method Detail
-
resolveSinkRef
public <T> SinkRef<T> resolveSinkRef(java.lang.String serializedSinkRef)
Description copied from interface:StreamRefResolver
Deserialize anSinkRef
in theStreamRefResolver.toSerializationFormat(akka.stream.SourceRef<T>)
.- Specified by:
resolveSinkRef
in interfaceStreamRefResolver
- Parameters:
serializedSinkRef
- (undocumented)- Returns:
- (undocumented)
-
resolveSourceRef
public <T> SourceRef<T> resolveSourceRef(java.lang.String serializedSourceRef)
Description copied from interface:StreamRefResolver
Deserialize anSourceRef
in theStreamRefResolver.toSerializationFormat(akka.stream.SourceRef<T>)
.- Specified by:
resolveSourceRef
in interfaceStreamRefResolver
- Parameters:
serializedSourceRef
- (undocumented)- Returns:
- (undocumented)
-
toSerializationFormat
public <T> java.lang.String toSerializationFormat(SourceRef<T> ref)
- Specified by:
toSerializationFormat
in interfaceStreamRefResolver
-
toSerializationFormat
public <T> java.lang.String toSerializationFormat(SinkRef<T> ref)
Description copied from interface:StreamRefResolver
Generate full String representation of theSinkRef
. This representation should be used as serialized representation.- Specified by:
toSerializationFormat
in interfaceStreamRefResolver
- Parameters:
ref
- (undocumented)- Returns:
- (undocumented)
-
-