Skip to content

Commit

Permalink
Apply dartfmt
Browse files Browse the repository at this point in the history
  • Loading branch information
Hyeonjae Park committed Nov 6, 2019
1 parent 67141fc commit 4ad2bfd
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
2 changes: 1 addition & 1 deletion lib/src/client/exchange.dart
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ abstract class Exchange {
/// Allocate a named [Queue], bind it to this exchange using the supplied [routingKeys],
/// allocate a [Consumer] and return a [Future<Consumer>].
///
/// You may specify a queue name and a [consumerTag] to label this consumer. If left unspecified,
/// You may specify a queue name and a [consumerTag] to label this consumer. If left unspecified,
/// the server will assign a random tag to this consumer. Consumer tags are local to the current channel.
///
/// The [noAck] flag will notify the server whether the consumer is expected to acknowledge incoming
Expand Down
3 changes: 2 additions & 1 deletion test/lib/exchange_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -302,7 +302,8 @@ main({bool enableLogger = true}) {
Channel channel = await client.channel();
Exchange exchange =
await channel.exchange("ex_test_1", ExchangeType.DIRECT);
Consumer consumer = await exchange.bindQueueConsumer("my_test_queue", ["test"]);
Consumer consumer =
await exchange.bindQueueConsumer("my_test_queue", ["test"]);
expect(consumer.channel, const TypeMatcher<Channel>());
expect(consumer.queue, const TypeMatcher<Queue>());
expect(consumer.tag, isNotEmpty);
Expand Down

0 comments on commit 4ad2bfd

Please sign in to comment.