Class MaybeSource


  • public class MaybeSource
    extends java.lang.Object
    INTERNAL API
    • Constructor Detail

      • MaybeSource

        public MaybeSource()
    • Method Detail

      • out

        public static Outlet<java.lang.Object> out()
      • shape

        public static SourceShape<java.lang.Object> shape()
      • initialAttributes

        protected static Attributes initialAttributes()
      • createLogicAndMaterializedValue

        public static scala.Tuple2<GraphStageLogic,​scala.concurrent.Promise<scala.Option<java.lang.Object>>> createLogicAndMaterializedValue​(Attributes inheritedAttributes)
      • toString

        public static java.lang.String toString()
      • named

        public static Graph<S,​M> named​(java.lang.String name)
      • async

        public static Graph<S,​M> async()
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher)
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher,
                                             int inputBufferSize)
      • addAttributes

        public static Graph<S,​M> addAttributes​(Attributes attr)
      • withAttributes

        public static final Graph<S,​M> withAttributes​(Attributes attr)