public class MetadataConsumer extends Object
Constructor and Description |
---|
MetadataConsumer(IMetadataService metadataService,
TorrentId torrentId,
Config config) |
Modifier and Type | Method and Description |
---|---|
void |
consume(ExtendedHandshake handshake,
MessageContext messageContext) |
void |
consume(UtMetadata message,
MessageContext context) |
void |
produce(Consumer<Message> messageConsumer,
MessageContext context) |
Torrent |
waitForTorrent() |
public MetadataConsumer(IMetadataService metadataService, TorrentId torrentId, Config config)
public void consume(ExtendedHandshake handshake, MessageContext messageContext)
public void consume(UtMetadata message, MessageContext context)
public void produce(Consumer<Message> messageConsumer, MessageContext context)
public Torrent waitForTorrent()
Copyright © 2016–2021. All rights reserved.