/*
 * Copyright (c) 2017, Oracle and/or its affiliates. All rights reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
 *
 * This code is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License version 2 only, as
 * published by the Free Software Foundation.  Oracle designates this
 * particular file as subject to the "Classpath" exception as provided
 * by Oracle in the LICENSE file that accompanied this code.
 *
 * This code is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
 * version 2 for more details (a copy is included in the LICENSE file that
 * accompanied this code).
 *
 * You should have received a copy of the GNU General Public License version
 * 2 along with this work; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
 *
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
 * or visit www.oracle.com if you need additional information or have any
 * questions.
 */

package jdk.incubator.http.internal.websocket;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.concurrent.CompletableFuture;

/*
 * The only parametrization of Transport<T> used is Transport<WebSocket>. The
 * type parameter T was introduced solely to avoid circular dependency between
 * Transport and WebSocket. After all, instances of T are used solely to
 * complete CompletableFutures. Transport doesn't care about the exact type of
 * T.
 *
 * This way the Transport is fully in charge of creating CompletableFutures.
 * On the one hand, Transport may use it to cache/reuse CompletableFutures. On
 * the other hand, the class that uses Transport, may benefit by not converting
 * from CompletableFuture<K> returned from Transport, to CompletableFuture<V>
 * needed by the said class.
 */
public interface Transport<T> {

    CompletableFuture<T> sendText(CharSequence message, boolean isLast);

    CompletableFuture<T> sendBinary(ByteBuffer message, boolean isLast);

    CompletableFuture<T> sendPing(ByteBuffer message);

    CompletableFuture<T> sendPong(ByteBuffer message);

    CompletableFuture<T> sendClose(int statusCode, String reason);

    void request(long n);

    /*
     * Why is this method needed? Since Receiver operates through callbacks
     * this method allows to abstract out what constitutes as a message being
     * received (i.e. to decide outside this type when exactly one should
     * decrement the demand).
     */
    void acknowledgeReception();

    void closeOutput() throws IOException;

    void closeInput() throws IOException;
}