Stream.swift

import Foundation

public protocol Stream: class {
    var isClosed: Bool { get }
    func close() throws

    func setTimeout(_ timeout: Double) throws
}

public protocol ReadableStream: Stream {
    func read(max: Int, into buffer: inout Data) throws -> Int
}

public protocol WriteableStream: Stream {
    func write(max: Int, from buffer: Data) throws -> Int
}

public typealias DuplexStream = ReadableStream & WriteableStream

// MARK: Program

public protocol InternetStream {
    var scheme: String { get }
    var hostname: String { get }
    var port: Port { get }
}

public protocol ClientStream: InternetStream, DuplexStream {
    func connect() throws
}

public protocol ServerStream: InternetStream {
    associatedtype Client: DuplexStream
    func bind() throws
    func listen(max: Int) throws
    func accept() throws -> Client
}

public typealias ProgramStream = ClientStream & ServerStream