in pekko-sample-sharding-java/killrweather/src/main/java/sample/killrweather/WeatherRoutes.java [71:90]
public Route weather() {
return path(segment("weather").slash().concat(longSegment()), wsid ->
concat(
get(() ->
parameter(dataTypeUnmarshaller, "type", (dataType ->
parameter(functionUnmarshaller, "function", (function ->
completeOKWithFuture(query(wsid, dataType, function), Jackson.marshaller())
))
))
),
post(() ->
entity(dataUnmarshaller, data ->
onSuccess(recordData(wsid, data), performed ->
complete(StatusCodes.ACCEPTED, performed + " from event time: " + data.eventTime)
)
)
)
)
);
}