duanebester

def greeter: Flow[Message, Message, Any] =
  Flow[Message].mapConcat {
    case tm: TextMessage =>
      TextMessage(Source.single("Hello ") ++ tm.textStream ++ Source.single("!")) :: Nil
    case bm: BinaryMessage =>
      // ignore binary messages but drain content to avoid the stream being clogged
      bm.dataStream.runWith(Sink.ignore)
      Nil
  }
val websocketRoute =

duanebester

val (wsActor, wsSource) = Source
  .actorRef[Message](32, OverflowStrategy.dropNew)
  .preMaterialize()

def wsStatusFlow(uuid: String): Flow[Message, Message, Any] =
  Flow.fromSinkAndSource(Sink.ignore, wsSource)

duanebester

val uploadRoute =
  pathPrefix("image") {
    path("upload") {
      post {
        uploadedFile("fileUpload") {
          case (_, file) =>
            val image = ImageIO.read(file)
            processImage(image)
            complete(StatusCodes.OK)
        }

duanebester

def processImage(bi: BufferedImage) = Source.single(bi).via(processImageFlow).runWith(Sink.ignore)

duanebester

def processImageFlow(): Flow[BufferedImage, ImageProcessed, NotUsed] =
  processStage(1)
    .via(processStage(2))
    .via(processStage(3))
    .via(processStage(4))
    .map(_ => ImageProcessed("Complete!"))

duanebester

def processStage(stageNum: Int) = Flow[BufferedImage]
  .async
  .delay(1 seconds)
  .map(bi => {
    println(s"Processing Stage: ${stageNum}")
    bi
  })

duanebester

const moveEnd = map => {
  const bbox = mapBoundsToBbox(map.getBounds());
  setBBox(bbox);
};

const onLoad = () => {
  setMapState({ zoom: [10], loaded: true });
};

duanebester

const mapBoundsToBbox = bounds => {
  const northWest = bounds.getNorthWest();
  const southEast = bounds.getSouthEast();
  const topLeft = {
    lat: `${northWest.lat}`,
    lon: `${northWest.lng}`
  };
  const bottomRight = {
    lat: `${southEast.lat}`,
    lon: `${southEast.lng}`

duanebester

const [bbox, setBBox] = useState({
  topLeft: {
    lat: null,
    lon: null
  },
  bottomRight: {
    lat: null,
    lon: null
  }
});

duanebester

const client = new ApolloClient({
  uri: "http://localhost:8080/graphql"
});

// inside function App()
return (
    <div className="App">
      <ApolloProvider client={client}>
        <Map
          {...mapConfig}