1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
//===----------------------------------------------------------------------===//
//
// This source file is part of the SwiftNIO open source project
//
// Copyright (c) 2017-2018 Apple Inc. and the SwiftNIO project authors
// Licensed under Apache License v2.0
//
// See LICENSE.txt for license information
// See CONTRIBUTORS.txt for the list of SwiftNIO project authors
//
// SPDX-License-Identifier: Apache-2.0
//
//===----------------------------------------------------------------------===//
import XCTest
import NIO
import NIOConcurrencyHelpers
struct NotImplementedError: Error { }
struct InvalidTypeError: Error { }
/// A basic ChannelCore that expects write0 to receive a NIOAny containing an Int.
///
/// Everything else either throws or returns a failed future, except for things that cannot,
/// which precondition instead.
private class IntChannelCore: ChannelCore {
func localAddress0() throws -> SocketAddress {
throw NotImplementedError()
}
func remoteAddress0() throws -> SocketAddress {
throw NotImplementedError()
}
func register0(promise: EventLoopPromise<Void>?) {
promise?.fail(NotImplementedError())
}
func registerAlreadyConfigured0(promise: EventLoopPromise<Void>?) {
promise?.fail(NotImplementedError())
}
func bind0(to: SocketAddress, promise: EventLoopPromise<Void>?) {
promise?.fail(NotImplementedError())
}
func connect0(to: SocketAddress, promise: EventLoopPromise<Void>?) {
promise?.fail(NotImplementedError())
}
func write0(_ data: NIOAny, promise: EventLoopPromise<Void>?) {
_ = self.unwrapData(data, as: Int.self)
promise?.succeed(())
}
func flush0() {
preconditionFailure("Must not flush")
}
func read0() {
preconditionFailure("Must not ew")
}
func close0(error: Error, mode: CloseMode, promise: EventLoopPromise<Void>?) {
promise?.fail(NotImplementedError())
}
func triggerUserOutboundEvent0(_ event: Any, promise: EventLoopPromise<Void>?) {
promise?.fail(NotImplementedError())
}
func channelRead0(_ data: NIOAny) {
preconditionFailure("Must not call channelRead0")
}
func errorCaught0(error: Error) {
preconditionFailure("Must not call errorCaught0")
}
}
class CustomChannelTests: XCTestCase {
func testWritingIntToSpecialChannel() throws {
let loop = EmbeddedEventLoop()
let intCore = IntChannelCore()
let writePromise = loop.makePromise(of: Void.self)
intCore.write0(NIOAny(5), promise: writePromise)
XCTAssertNoThrow(try writePromise.futureResult.wait())
}
}
|
