/**
 * Copyright (c) 2018-present, tarant
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 */ import Message from './message' ; import Partition from './partition' ; export default interface ISubscriber < T > { partitions : Partition [ ] ; onReceiveMessage ( message ) : Promise < boolean > ; }