static public Consumer publishMarketDepth()

in simulator/src/main/java/com/google/cloud/PubSubConsumer.java [78:85]

• 7 lines of code
• 1 McCabe index (conditional complexity)

  static public Consumer<MarketDepth> publishMarketDepth(Consumer<PubsubMessage> consumer) {
    return payload -> {
      PubsubMessage.Builder b = PubsubMessage.newBuilder();
      b.setData(payload.toByteString());

      consumer.accept(b.build());
    };
  }