then:
        result == failure
    }

    def "receive ignores stdin messages"() {
        when:
        connection.queueIncoming("incoming1")
        connection.queueIncoming(new ForwardInput("yo".bytes))
        connection.queueIncoming(new CloseInput())
        connection.queueIncoming("incoming2")
        def result = []
        result << daemonConnection.receive(20, TimeUnit.SECONDS)

        hub.addConnection(connection)

        when:
        connection.queueIncoming(new ChannelMessage(new ChannelIdentifier("channel 1"), "message 1"))
        connection.queueIncoming(new ChannelMessage(new ChannelIdentifier("channel 2"), "message 2"))
        connection.queueIncoming(new ChannelMessage(new ChannelIdentifier("channel 1"), "message 3"))
        thread.blockUntil.channel1Received

        def worker = Mock(Worker)
        def connection = new TestConnection()

        given:
        connectCompletion.create(_) >> connection
        connection.queueIncoming(new ChannelMessage(new ChannelIdentifier(Worker.name), new MethodInvocation(Worker.class.getMethod("doStuff", String), ["param 1"] as Object[])))

        when:
        connectionBuilder.addIncoming(Worker, worker)

        def message = incoming.take()
        return message == END ? null : (InterHubMessage) message
    }

    /**
     * Queues the given message to return from {@link #receive()}.
     */
    void queueIncoming(InterHubMessage message) {
        incoming.put(message)
    }

    /**
     * Marks the end of the incoming messages.
     */
    @Override
    void stop() {
        incoming.put(END)
    }