public/dart/fuchsia_services/test/outgoing_test.dart

// Copyright 2019 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

// ignore_for_file: implementation_imports
import 'dart:async';
import 'package:fidl/fidl.dart';
import 'package:fidl_fuchsia_io/fidl_async.dart';
import 'package:fuchsia_services/src/outgoing.dart';
import 'package:test/test.dart';

void main() {
  group('outgoing', () {
    test('connect to service calls correct service', () async {
      final outgoingImpl = Outgoing();
      final dirProxy = DirectoryProxy();
      final nodeProxy = NodeProxy();
      final streamController = StreamController<bool>.broadcast();
      final stream = streamController.stream;

      outgoingImpl
        ..addPublicService((_) {
          streamController
            ..add(true)
            ..close();
        }, 'foo',)
        ..serve(InterfaceRequest(dirProxy.ctrl.request().passChannel()));

      await dirProxy.open(0, 0, 'public/foo', nodeProxy.ctrl.request());
      stream.listen(expectAsync1((response) {
        expect(response, true);
      }));
    });
  });
}