blob: 06c5030676653eda226287cec368a1aa0385f6ce [file] [log] [blame]
// Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
import 'dart:io';
import 'package:analysis_server/src/channel/byte_stream_channel.dart';
import 'package:analysis_server/src/socket_server.dart';
/// Instances of the class [StdioServer] implement a simple server operating
/// over standard input and output. The primary responsibility of this server
/// is to split incoming messages on newlines and pass them along to the
/// analysis server.
class StdioAnalysisServer {
/// An object that can handle either a WebSocket connection or a connection
/// to the client over stdio.
SocketServer socketServer;
/// Initialize a newly created stdio server.
StdioAnalysisServer(this.socketServer);
/// Begin serving requests over stdio.
///
/// Return a future that will be completed when stdin closes.
Future serveStdio() {
var serverChannel = ByteStreamServerChannel(
stdin,
stdout,
socketServer.instrumentationService,
requestStatistics: socketServer.requestStatistics,
);
socketServer.createAnalysisServer(serverChannel);
return serverChannel.closed;
}
}