dart:io

Класс Socket

TCP-соединение между двумя сокетами.

Соединение сокета подключает локальный сокет к удаленному сокету. Данные, в виде Uint8List, принимаются локальным сокетом, доступны через интерфейс Stream этого класса, и могут быть отправлены в удалённый сокет через интерфейс IOSink этого класса.

Реализуемые типы

• Stream<Uint8List>
• IOSink

Реализации

• SecureSocket

Конструкторы

Socket()

Свойства

address → InternetAddress

только для чтения

InternetAddress, используемый для подключения к этому сокету.

done → Future

только для чтения, переопределение

Future, который выполнится, когда потребитель закроет сокет или произойдёт ошибка.

encoding ↔ Encoding

чтение/запись, унаследованное

Encoding, используемый при записи строк.

first → Future<Uint8List>

только для чтения, унаследованное

Первый элемент этого потока.

hashCode → int

только для чтения, унаследованное

Код хеширования для этого объекта.

isBroadcast → bool

только для чтения, унаследованное

Является ли этот поток потоком широковещательной передачи.

isEmpty → Future<bool>

только для чтения, унаследованное

Содержит ли этот поток какие-либо элементы.

last → Future<Uint8List>

только для чтения, унаследованное

Последний элемент этого потока.

length → Future<int>

только для чтения, унаследованное

Количество элементов в этом потоке.

port → int

только для чтения

Порт, используемый этим сокетом.

remoteAddress → InternetAddress

только для чтения

Удалённый InternetAddress, подключённый к этому сокету.

remotePort → int

только для чтения

Удалённый порт, подключённый к этому сокету.

runtimeType → Type

только для чтения, унаследованное

Представление runtime-типа объекта.

single → Future<Uint8List>

только для чтения, унаследованное

Единственный элемент этого потока.

Методы

add(List<int> data) → void

inherited

Добавляет байты data к целевому потребителю, игнорируя кодировку.

addError(Object error, [StackTrace? stackTrace]) → void

inherited

Передает ошибку целевому потребителю как событие ошибки.

addStream(Stream<List<int>> stream) → Future

inherited

Добавляет все элементы данного stream.

any(bool test(Uint8List element)) → Future<bool>

inherited

Проверяет, принимает ли test любой элемент, предоставленный этим потоком.

asBroadcastStream({void onListen(StreamSubscription<Uint8List> subscription)?, void onCancel(StreamSubscription<Uint8List> subscription)?}) → Stream<Uint8List>

inherited

Возвращает поток с множественными подписками, который производит те же события, что и этот.

asyncExpand<E>(Stream<E>? convert(Uint8List event)) → Stream<E>

inherited

Преобразует каждый элемент в последовательность асинхронных событий.

asyncMap<E>(FutureOr<E> convert(Uint8List event)) → Stream<E>

inherited

Создает новый поток, в котором каждое событие данных этого потока асинхронно отображается на новое событие.

cast<R>() → Stream<R>

inherited

Адаптирует этот поток к Stream<R>.

close() → Future

override

Закрывает целевого потребителя.

contains(Object? needle) → Future<bool>

inherited

Возвращает значение, если needle встречается в элементах, предоставленных этим потоком.

destroy() → void

Уничтожает сокет в обоих направлениях.

distinct([bool equals(Uint8List previous, Uint8List next)?]) → Stream<Uint8List>

inherited

Пропускает события данных, если они равны предыдущему событию данных.

drain<E>([E? futureValue]) → Future<E>

inherited

Отбрасывает все данные в этом потоке, но сигнализирует, когда он завершен или произошла ошибка.

elementAt(int index) → Future<Uint8List>

inherited

Возвращает значение index-го события данных этого потока.

every(bool test(Uint8List element)) → Future<bool>

inherited

Проверяет, принимает ли test все элементы, предоставленные этим потоком.

expand<S>(Iterable<S> convert(Uint8List element)) → Stream<S>

inherited

Преобразует каждый элемент этого потока в последовательность элементов.

firstWhere(bool test(Uint8List element), {Uint8List orElse()?}) → Future<Uint8List>

inherited

Находит первый элемент этого потока, соответствующий test.

flush() → Future

inherited

Возвращает Future, который завершается, как только все буферизованные данные принимаются базовым StreamConsumer.

fold<S>(S initialValue, S combine(S previous, Uint8List element)) → Future<S>

inherited

Объединяет последовательность значений, многократно применяя combine.

forEach(void action(Uint8List element)) → Future

inherited

Выполняет action над каждым элементом этого потока.

getRawOption(RawSocketOption option) → Uint8List

Считывает низкоуровневую информацию о RawSocket.

handleError(Function onError, {bool test(dynamic error)?}) → Stream<Uint8List>

inherited

Создаёт оборачивающий поток, который перехватывает некоторые ошибки из этого потока.

join([String separator = ""]) → Future<String>

inherited

Объединяет строковое представление элементов в одну строку.

lastWhere(bool test(Uint8List element), {Uint8List orElse()?}) → Future<Uint8List>

inherited

Находит последний элемент в этом потоке, соответствующий test.

listen(void onData(Uint8List event)?, {Function? onError, void onDone()?, bool? cancelOnError}) → StreamSubscription<Uint8List>

inherited

Добавляет подписку на этот поток.

map<S>(S convert(Uint8List event)) → Stream<S>

inherited

Преобразует каждый элемент этого потока в новое событие потока.

noSuchMethod(Invocation invocation) → dynamic

inherited

Вызывается при обращении к несуществующему методу или свойству.

pipe(StreamConsumer<Uint8List> streamConsumer) → Future

inherited

Перенаправляет события этого потока в streamConsumer.

reduce(Uint8List combine(Uint8List previous, Uint8List element)) → Future<Uint8List>

inherited

Объединяет последовательность значений, многократно применяя combine.

setOption(SocketOption option, bool enabled) → bool

Настраивает RawSocket.

setRawOption(RawSocketOption option) → void

Настраивает RawSocket.

singleWhere(bool test(Uint8List element), {Uint8List orElse()?}) → Future<Uint8List>

inherited

Находит единственный элемент в этом потоке, соответствующий test.

skip(int count) → Stream<Uint8List>

inherited

Пропускает первые count события данных из этого потока.

skipWhile(bool test(Uint8List element)) → Stream<Uint8List>

inherited

Пропускает события данных из этого потока, пока они соответствуют test.

take(int count) → Stream<Uint8List>

inherited

Предоставляет не более первых count событий данных из этого потока.

takeWhile(bool test(Uint8List element)) → Stream<Uint8List>

inherited

Пересылает события данных, пока test выполняется успешно.

timeout(Duration timeLimit, {void onTimeout(EventSink<Uint8List> sink)?}) → Stream<Uint8List>

inherited

Создаёт новый поток с теми же событиями, что и этот поток.

toList() → Future<List<Uint8List>>

inherited

Собирает все элементы этого потока в List.

toSet() → Future<Set<Uint8List>>

inherited

Собирает данные этого потока в Set.

toString() → String

inherited

Строковое представление этого объекта.

transform<S>(StreamTransformer<Uint8List, S> streamTransformer) → Stream<S>

inherited

Применяет streamTransformer к этому потоку.

where(bool test(Uint8List event)) → Stream<Uint8List>

inherited

Создаёт новый поток из этого потока, отбрасывая некоторые элементы.

write(Object? object) → void

inherited

Преобразует object в строку, вызывая Object.toString, и добавляет кодировку результата к целевому потребителю.

writeAll(Iterable objects, [String separator = ""]) → void

inherited

Перебирает заданный objects и writeт их последовательно.

writeCharCode(int charCode) → void

inherited

Записывает символ charCode.

writeln([Object? object = ""]) → void

inherited

Преобразует object в строку, вызывая Object.toString, и записывает результат в this, после чего добавляется новая строка.

Операторы

operator ==(Object other) → bool

inherited

Оператор равенства.

Статические методы

connect(dynamic host, int port, {dynamic sourceAddress, int sourcePort = 0, Duration? timeout}) → Future<Socket>

Создаёт новое сокет-соединение с указанным хостом и портом, возвращает Future, которое завершится либо подключением, либо ошибкой, если поиск хоста или подключение завершилось неудачно.

startConnect(dynamic host, int port, {dynamic sourceAddress, int sourcePort = 0}) → Future<ConnectionTask<Socket>>

Аналогично connect, но возвращает Future, которое завершается с задачей подключения, которую можно отменить, если сокет больше не нужен.