@Override
  public void encode(T value, OutputStream outStream) throws CoderException, IOException {
    Serializer<T> serializer = this.serialization.getSerializer(type);
    serializer.open(new UncloseableOutputStream(outStream));
    try {
      serializer.serialize(value);
    } finally {
      serializer.close();
    }
  }
@ Override public void encode ( T value , OutputStream outStream ) throws CoderException , IOException { Serializer < T > serializer = this . serialization . getSerializer ( type ) ; serializer . open ( new UncloseableOutputStream ( outStream ) ) ; try { serializer . serialize ( value ) ; } finally { serializer . close ( ) ; } }
{@inheritDoc}