* See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.internal.serialize;

public interface ObjectWriter<T> {
    void write(T value) throws Exception;

                    return serializer.read(decoder);
                }
            };
        }

        @Override
        public ObjectWriter<T> newWriter(final Encoder encoder) {
            return new ObjectWriter<T>() {
                @Override
                public void write(T value) throws Exception {
                    serializer.write(encoder, value);
                }
            };

    private final SocketChannel socket;
    private final SocketInetAddress localAddress;
    private final SocketInetAddress remoteAddress;
    private final ObjectWriter<T> objectWriter;
    private final ObjectReader<T> objectReader;
    private final InputStream instr;
    private final OutputStream outstr;
    private final FlushableEncoder encoder;

        }
    }

    private static class MessageWriter implements ObjectWriter<InterHubMessage> {
        private final Map<ChannelIdentifier, Integer> channels = new HashMap<ChannelIdentifier, Integer>();
        private final Encoder encoder;
        private final ObjectWriter<Object> payloadWriter;

        public MessageWriter(Encoder encoder, ObjectWriter<Object> payloadWriter) {
            this.encoder = encoder;

                return reader.read();
            }
        };
    }

    @Override
    public ObjectWriter<Object> newWriter(Encoder encoder) {
        final ObjectWriter<T> writer = serializer.newWriter(encoder);
        return new ObjectWriter<Object>() {
            @Override
            public void write(Object value) throws Exception {
                writer.write(type.cast(value));

public interface StatefulSerializer<T> {
    /**
     * Should not perform any buffering
     */
    ObjectReader<T> newReader(Decoder decoder);

    /**
     * Should not perform any buffering
     */
    ObjectWriter<T> newWriter(Encoder encoder);

    }

    @Override
    public ObjectReader<MethodInvocation> newReader(Decoder decoder) {
        return new MethodInvocationReader(decoder, classLoader, methodArgsSerializer);
    }

    @Override
    public ObjectWriter<MethodInvocation> newWriter(Encoder encoder) {
        return new MethodInvocationWriter(encoder, methodArgsSerializer);
    }

    private static class MethodDetails {
        final int methodId;

Class <org.gradle.internal.serialize.ObjectReader> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (ObjectReader.java:0)
Class <org.gradle.internal.serialize.ObjectWriter> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (ObjectWriter.java:0)
Class <org.gradle.internal.serialize.OutputStreamBackedEncoder> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (OutputStreamBackedEncoder.java:0)