// Path: src/main/java/org/arbeitspferde/groningen/utility/logstream/OutputLogStream.java
// @NotThreadSafe
// public interface OutputLogStream extends Flushable, Closeable {
//   public void write(final Message message) throws IOException;
// }


import com.google.protobuf.Message;
import org.arbeitspferde.groningen.utility.logstream.OutputLogStream;
import org.arbeitspferde.groningen.utility.logstream.OutputLogStreamFactory;
import javax.annotation.concurrent.ThreadSafe;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
package org.arbeitspferde.groningen.utility.logstream.format.open;





/**
 * <p>{@link DelimitedFactory} furnishes {@link OutputLogStream}s that use use Protocol Buffers'
 * underlying delimited encoding per {@link Message#writeDelimitedTo(OutputStream)}.
 * </p>
 *
 * {@inheritDoc}
 */
@ThreadSafe
public class DelimitedFactory implements OutputLogStreamFactory {
  @Override
// Path: src/main/java/org/arbeitspferde/groningen/utility/logstream/OutputLogStream.java
// @NotThreadSafe
// public interface OutputLogStream extends Flushable, Closeable {
//   public void write(final Message message) throws IOException;
// }


// Path: src/main/java/org/arbeitspferde/groningen/utility/logstream/format/open/DelimitedFactory.java
import com.google.protobuf.Message;
import org.arbeitspferde.groningen.utility.logstream.OutputLogStream;
import org.arbeitspferde.groningen.utility.logstream.OutputLogStreamFactory;
import javax.annotation.concurrent.ThreadSafe;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;

package org.arbeitspferde.groningen.utility.logstream.format.open;





/**
 * <p>{@link DelimitedFactory} furnishes {@link OutputLogStream}s that use use Protocol Buffers'
 * underlying delimited encoding per {@link Message#writeDelimitedTo(OutputStream)}.
 * </p>
 *
 * {@inheritDoc}
 */
@ThreadSafe
public class DelimitedFactory implements OutputLogStreamFactory {
  @Override
  public OutputLogStream forStream(final OutputStream stream) throws IOException {