public OrderBookMutableState decode()

in order-book-pipeline/src/main/java/com/google/cloud/dataflow/orderbook/OrderBookCoder.java [66:74]


  public OrderBookMutableState decode(InputStream inStream) throws IOException {
    int depth = intCoder.decode(inStream);
    boolean withTrade = booleanCoder.decode(inStream);
    Map<Long, Long> prices = mapCoder.decode(inStream);
    OrderBookEvent lastOrderBookEvent = orderBookEventCoder.decode(inStream);
    OrderBookMutableState orderBookMutableState = new OrderBookMutableState(depth, withTrade,
        prices, lastOrderBookEvent);
    return orderBookMutableState;
  }