Package: AbstractWriter

AbstractWriter

name	instruction	branch	complexity	line	method
AbstractWriter()	M: 3 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
write(Connection, Object, WritableMessage)	M: 13 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 3 C: 0 0%	M: 1 C: 0 0%
write(Connection, Object, WritableMessage, CompletionHandler)	M: 9 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 2 C: 0 0%	M: 1 C: 0 0%
write(Connection, WritableMessage)	M: 6 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
write(Connection, WritableMessage, CompletionHandler)	M: 9 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 2 C: 0 0%	M: 1 C: 0 0%

Coverage

1: /*
2: * Copyright (c) 2008, 2020 Oracle and/or its affiliates. All rights reserved.
3: *
4: * This program and the accompanying materials are made available under the
5: * terms of the Eclipse Public License v. 2.0, which is available at
6: * http://www.eclipse.org/legal/epl-2.0.
7: *
8: * This Source Code may also be made available under the following Secondary
9: * Licenses when the conditions for such availability set forth in the
10: * Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
11: * version 2 with the GNU Classpath Exception, which is available at
12: * https://www.gnu.org/software/classpath/license.html.
13: *
14: * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
15: */
16:
17: package org.glassfish.grizzly;
18:
19: import org.glassfish.grizzly.asyncqueue.MessageCloner;
20: import org.glassfish.grizzly.asyncqueue.WritableMessage;
21: import org.glassfish.grizzly.impl.FutureImpl;
22: import org.glassfish.grizzly.utils.Futures;
23:
24: /**
25: * Abstract class, which provides transitive dependencies for overloaded {@link Writer} methods.
26: *
27: * @author Alexey Stashok
28: */
29: @SuppressWarnings("deprecation")
30: public abstract class AbstractWriter<L> implements Writer<L> {
31:
32: /**
33: * {@inheritDoc}
34: */
35: @Override
36: public final GrizzlyFuture<WriteResult<WritableMessage, L>> write(final Connection<L> connection, final WritableMessage message) {
37: return write(connection, null, message);
38: }
39:
40: /**
41: * {@inheritDoc}
42: */
43: @Override
44: @SuppressWarnings("unchecked")
45: public final void write(final Connection<L> connection, final WritableMessage message,
46: final CompletionHandler<WriteResult<WritableMessage, L>> completionHandler) {
47: write(connection, null, message, completionHandler, (MessageCloner) null);
48: }
49:
50: /**
51: * {@inheritDoc}
52: */
53: @Override
54: @SuppressWarnings("unchecked")
55: public final GrizzlyFuture<WriteResult<WritableMessage, L>> write(final Connection<L> connection, final L dstAddress, final WritableMessage message) {
56: final FutureImpl<WriteResult<WritableMessage, L>> future = Futures.createSafeFuture();
57:
58: write(connection, dstAddress, message, Futures.toCompletionHandler(future), (MessageCloner) null);
59:
60: return future;
61: }
62:
63: /**
64: * {@inheritDoc}
65: */
66: @Override
67: @SuppressWarnings("unchecked")
68: public final void write(final Connection<L> connection, final L dstAddress, final WritableMessage message,
69: final CompletionHandler<WriteResult<WritableMessage, L>> completionHandler) {
70: write(connection, dstAddress, message, completionHandler, (MessageCloner) null);
71: }
72:
73: }