Type Members

1.  abstract class GrpcServerLogic extends HttpServerLogic

   Annotations

   @ApiMayChange()

2.  abstract class HttpServerLogic extends scaladsl.HttpServerLogic

   cloudflow.akkastream.ServerStreamletLogic for accepting HTTP requests.

   cloudflow.akkastream.ServerStreamletLogic for accepting HTTP requests. Requires a Server to be passed in when it is created. cloudflow.akkastream.AkkaServerStreamlet extends cloudflow.akkastream.Server, which can be used for this purpose. When you define the logic inside the streamlet, you can just pass in this:

   HttpServerLogic also predefined logics (HttpServerLogic.createDefault and HttpServerLogic.createDefaultStreaming) for accepting, transcoding, and writing to an outlet.

   class TestHttpServer extends AkkaServerStreamlet {
     AvroOutlet<Data> outlet = AvroOutlet.<Data>create("out",  d -> d.name(), Data.class);
     Unmarshaller<ByteString, Data> fbu = Jackson.byteStringUnmarshaller(Data.class);
   
      public StreamletShape shape() {
        return StreamletShape.createWithOutlets(outlet);
      }
   
      public HttpServerLogic createLogic() {
        return new HttpServerLogic(this, getStreamletContext()) {
          Route createRoute() {
            // define HTTP route here
          }
        }
      }
    }

3.  final class MergeLogic[T] extends scaladsl.MergeLogic[T]

   Java API A MergeLogic merges two or more inlets into one outlet.

   Java API A MergeLogic merges two or more inlets into one outlet. Elements from all inlets will be processed with at-least-once semantics. The elements will be processed in semi-random order and with equal priority for all inlets.

   Annotations

   @deprecated

   Deprecated

   (Since version 1.3.1) Use Merger.source instead.

4.  abstract class SplitterLogic[I, L, R] extends scaladsl.SplitterLogic[I, L, R]

   Annotations

   @deprecated

   Deprecated

   (Since version 1.3.1) Use Splitter.sink instead.