Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

rhea-promise

Package Overview
Dependencies
Maintainers
4
Versions
27
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

rhea-promise - npm Package Compare versions

Comparing version 2.0.0 to 2.1.0

12

changelog.md

@@ -0,1 +1,7 @@

### 2.1.0 - (2021-06-30)
- Exposes a new `receiver.drainCredit()` method that calls through to rhea's
`receiver.drain_credit()` method.
- Update rhea minimum version to 2.0.3
### 2.0.0 - (2021-06-03)

@@ -13,5 +19,5 @@

- Renames the following TypeScript interfaces to better match the methods they apply to:
- SenderOptionsWithSession -> CreateSenderOptions
- AwaitableSenderOptionsWithSession -> CreateAwaitableSenderOptions
- ReceiverOptionsWithSession -> CreateReceiverOptions
- SenderOptionsWithSession -> CreateSenderOptions
- AwaitableSenderOptionsWithSession -> CreateAwaitableSenderOptions
- ReceiverOptionsWithSession -> CreateReceiverOptions

@@ -18,0 +24,0 @@ ### 1.2.1 - (2021-04-15)

@@ -23,2 +23,5 @@ "use strict";

}
drainCredit() {
this._link.drain_credit();
}
setCreditWindow(creditWindow) {

@@ -25,0 +28,0 @@ this._link.set_credit_window(creditWindow);

@@ -6,3 +6,5 @@ // Copyright (c) Microsoft Corporation. All rights reserved.

import {
ReceiverEvents, Receiver as RheaReceiver, ReceiverOptions as RheaReceiverOptions
ReceiverEvents,
Receiver as RheaReceiver,
ReceiverOptions as RheaReceiverOptions,
} from "rhea";

@@ -62,3 +64,7 @@ import { Link, LinkType } from "./link";

export class Receiver extends Link {
constructor(session: Session, receiver: RheaReceiver, options?: ReceiverOptions) {
constructor(
session: Session,
receiver: RheaReceiver,
options?: ReceiverOptions
) {
super(LinkType.receiver, session, receiver, options);

@@ -79,2 +85,6 @@ }

drainCredit(): void {
(this._link as RheaReceiver).drain_credit();
}
setCreditWindow(creditWindow: number): void {

@@ -81,0 +91,0 @@ (this._link as RheaReceiver).set_credit_window(creditWindow);

{
"name": "rhea-promise",
"version": "2.0.0",
"version": "2.1.0",
"description": "A Promisified layer over rhea AMQP client",

@@ -10,3 +10,3 @@ "license": "Apache-2.0",

"debug": "^3.1.0",
"rhea": "^2.0.1",
"rhea": "^2.0.3",
"tslib": "^2.2.0"

@@ -13,0 +13,0 @@ },

@@ -56,4 +56,5 @@ import { Session } from "./session";

addCredit(credit: number): void;
drainCredit(): void;
setCreditWindow(creditWindow: number): void;
}
//# sourceMappingURL=receiver.d.ts.map

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc