export interface Close {
  readonly [CloseTypeId]: CloseTypeId
  readonly close: Effect.Effect<void, NATSError.JetStreamConsumerError>
  readonly closed: Effect.Effect<void, NATSError.JetStreamConsumerError>
}

export interface Consumer extends ExportedConsumer, InfoableConsumer, DeleteableConsumer {
  readonly [ConsumerTypeId]: ConsumerTypeId

  /** @internal */
  readonly consumer: JetStream.Consumer
}

export interface ConsumerKind {
  readonly [ConsumerKindTypeId]: ConsumerKindTypeId
  readonly isPullConsumer: Effect.Effect<boolean, NATSError.JetStreamConsumerError>
  readonly isPushConsumer: Effect.Effect<boolean, NATSError.JetStreamConsumerError>
}

export interface ConsumerMessages
  extends Omit<
      NATSQueuedIterator.NATSQueuedIterator<JetStreamMessage.JetStreamMessage, NATSError.JetStreamConsumerError>,
      "iterator"
    >,
    Close {
  readonly [ConsumerMessagesTypeId]: ConsumerMessagesTypeId
  readonly status: Effect.Effect<
    Stream.Stream<JetStream.ConsumerNotification, NATSError.JetStreamConsumerError>,
    NATSError.JetStreamConsumerError
  >

  /** @internal */
  readonly consumerMessages: JetStream.ConsumerMessages
}

export interface Consumers {
  readonly [ConsumersTypeId]: ConsumersTypeId
  readonly get: (
    ...args: Parameters<JetStream.Consumers["get"]>
  ) => Effect.Effect<Consumer, NATSError.JetStreamConsumerError>
  readonly getConsumerFromInfo: (
    ...args: Parameters<JetStream.Consumers["getConsumerFromInfo"]>
  ) => Effect.Effect<Consumer, NATSError.JetStreamConsumerError>
  readonly getPushConsumer: (
    ...args: Parameters<JetStream.Consumers["getPushConsumer"]>
  ) => Effect.Effect<PushConsumer, NATSError.JetStreamConsumerError>
  readonly getBoundPushConsumer: (
    ...args: Parameters<JetStream.Consumers["getBoundPushConsumer"]>
  ) => Effect.Effect<PushConsumer, NATSError.JetStreamConsumerError>

  /** @internal */
  readonly consumers: JetStream.Consumers
}

export interface DeleteableConsumer {
  readonly [DeleteableConsumerTypeId]: DeleteableConsumerTypeId
  readonly delete: Effect.Effect<boolean, NATSError.JetStreamConsumerError>
}

export interface ExportedConsumer extends ConsumerKind {
  readonly [ExportedConsumerTypeId]: ExportedConsumerTypeId
  readonly next: (
    ...args: Parameters<JetStream.Consumer["next"]>
  ) => Effect.Effect<Option.Option<JetStreamMessage.JetStreamMessage>, NATSError.JetStreamConsumerError>
  readonly fetch: (
    ...args: Parameters<JetStream.Consumer["fetch"]>
  ) => Effect.Effect<ConsumerMessages, NATSError.JetStreamConsumerError>
  readonly consume: (
    ...args: Parameters<JetStream.Consumer["consume"]>
  ) => Effect.Effect<ConsumerMessages, NATSError.JetStreamConsumerError>
}

export interface InfoableConsumer {
  readonly [InfoableConsumerTypeId]: InfoableConsumerTypeId
  readonly info: (
    ...args: Parameters<JetStream.Consumer["info"]>
  ) => Effect.Effect<JetStream.ConsumerInfo, NATSError.JetStreamConsumerError>
}

export interface PushConsumer extends InfoableConsumer, DeleteableConsumer, ConsumerKind {
  readonly [PushConsumerTypeId]: PushConsumerTypeId
  readonly consume: (
    ...args: Parameters<JetStream.PushConsumer["consume"]>
  ) => Effect.Effect<ConsumerMessages, NATSError.JetStreamConsumerError>

  /** @internal */
  readonly pushConsumer: JetStream.PushConsumer
}

export declare const CloseTypeId: typeof CloseTypeId

export type CloseTypeId = typeof CloseTypeId

export declare const ConsumerKindTypeId: typeof ConsumerKindTypeId

export type ConsumerKindTypeId = typeof ConsumerKindTypeId

export declare const ConsumerMessagesTypeId: typeof ConsumerMessagesTypeId

export type ConsumerMessagesTypeId = typeof ConsumerMessagesTypeId

export declare const ConsumerTypeId: typeof ConsumerTypeId

export type ConsumerTypeId = typeof ConsumerTypeId

export declare const ConsumersTypeId: typeof ConsumersTypeId

export type ConsumersTypeId = typeof ConsumersTypeId

export declare const DeleteableConsumerTypeId: typeof DeleteableConsumerTypeId

export type DeleteableConsumerTypeId = typeof DeleteableConsumerTypeId

export declare const ExportedConsumerTypeId: typeof ExportedConsumerTypeId

export type ExportedConsumerTypeId = typeof ExportedConsumerTypeId

export declare const InfoableConsumerTypeId: typeof InfoableConsumerTypeId

export type InfoableConsumerTypeId = typeof InfoableConsumerTypeId

export declare const PushConsumerTypeId: typeof PushConsumerTypeId

export type PushConsumerTypeId = typeof PushConsumerTypeId