@types/stompit
Advanced tools
Comparing version 0.26.3 to 0.26.4
@@ -8,4 +8,4 @@ // Type definitions for stompit 0.26 | ||
import { Writable, Readable, Duplex, WritableOptions } from "stream"; | ||
import { EventEmitter } from "events"; | ||
import { Duplex, Readable, Writable, WritableOptions } from "stream"; | ||
@@ -12,0 +12,0 @@ export import IncomingFrameStream = require("./lib/IncomingFrameStream"); |
import { EventEmitter } from "events"; | ||
import { Readable } from "stream"; | ||
import { Message, Ack, MessageCallback, SendOptions } from "./Client"; | ||
import { Ack, Message, MessageCallback, SendOptions } from "./Client"; | ||
import ConnectFailover = require("./ConnectFailover"); | ||
@@ -13,3 +13,10 @@ import Transaction = require("./client/Transaction"); | ||
subscribe(headers: any, onMessageCallback: (err: Error | null, message: Message, channelSubscription: Channel.ChannelSubscription) => void): Channel.ChannelSubscription; | ||
subscribe( | ||
headers: any, | ||
onMessageCallback: ( | ||
err: Error | null, | ||
message: Message, | ||
channelSubscription: Channel.ChannelSubscription, | ||
) => void, | ||
): Channel.ChannelSubscription; | ||
setImplicitSubscription(id: number, ack?: Ack, msgListener?: MessageCallback): Channel.ChannelSubscription; | ||
@@ -16,0 +23,0 @@ |
@@ -1,2 +0,2 @@ | ||
import { WritableOptions, Writable, Readable, Duplex } from "stream"; | ||
import { Duplex, Readable, Writable, WritableOptions } from "stream"; | ||
import { IncomingFrame } from "./IncomingFrameStream"; | ||
@@ -15,3 +15,8 @@ import { SocketOptions } from "./Socket"; | ||
sendFrame(command: string, headers?: any, options?: Client.SendOptions): Writable; | ||
sendString(headers?: any, body?: any, options?: Client.SendOptions, callback?: (error?: Error | null) => void): void; | ||
sendString( | ||
headers?: any, | ||
body?: any, | ||
options?: Client.SendOptions, | ||
callback?: (error?: Error | null) => void, | ||
): void; | ||
@@ -27,4 +32,14 @@ connect(headers?: any, callback?: (err: Error | null, client: Client) => void): void; | ||
ack(message: Client.Message, headers?: any, sendOptions?: Client.SendOptions, callback?: (error?: Error | null) => void): void; | ||
nack(message: Client.Message, headers?: any, sendOptions?: Client.SendOptions, callback?: (error?: Error | null) => void): void; | ||
ack( | ||
message: Client.Message, | ||
headers?: any, | ||
sendOptions?: Client.SendOptions, | ||
callback?: (error?: Error | null) => void, | ||
): void; | ||
nack( | ||
message: Client.Message, | ||
headers?: any, | ||
sendOptions?: Client.SendOptions, | ||
callback?: (error?: Error | null) => void, | ||
): void; | ||
@@ -31,0 +46,0 @@ readEmptyBody(frame: IncomingFrameStream, callback?: (client: Client) => void): void; |
@@ -0,3 +1,3 @@ | ||
import { Readable, Writable } from "stream"; | ||
import { Ack, MessageCallback } from "../Client"; | ||
import { Readable, Writable } from "stream"; | ||
@@ -4,0 +4,0 @@ import Client = require("../Client"); |
@@ -1,2 +0,2 @@ | ||
import { Socket, TcpNetConnectOpts, IpcNetConnectOpts } from "net"; | ||
import { IpcNetConnectOpts, Socket, TcpNetConnectOpts } from "net"; | ||
import { ConnectionOptions as TlsConnectionOptions } from "tls"; | ||
@@ -9,3 +9,4 @@ | ||
optionsOrPathOrPort: connect.ConnectOptions | string | number, | ||
connectionListener?: connect.ConnectionListener): Client; | ||
connectionListener?: connect.ConnectionListener, | ||
): Client; | ||
declare function connect(port: number, host?: string, connectionListener?: connect.ConnectionListener): Client; | ||
@@ -12,0 +13,0 @@ |
import { EventEmitter } from "events"; | ||
import { ConnectOptions, ConnectionListener } from "./connect"; | ||
import { ConnectionListener, ConnectOptions } from "./connect"; | ||
import { AddressInfo } from "./connect-failover/getAddressInfo"; | ||
@@ -14,7 +14,12 @@ | ||
connect(callback: (error: Error | null, client: Client, reconnect: () => void, server: ConnectFailover.Server) => void): { | ||
connect( | ||
callback: (error: Error | null, client: Client, reconnect: () => void, server: ConnectFailover.Server) => void, | ||
): { | ||
abort: () => void; | ||
}; | ||
on(event: "error", listener: (err: ConnectFailover.ConnectError, server: ConnectFailover.ConnectState) => void): this; | ||
on( | ||
event: "error", | ||
listener: (err: ConnectFailover.ConnectError, server: ConnectFailover.ConnectState) => void, | ||
): this; | ||
on(event: "connect" | "connecting", listener: (server: ConnectFailover.ConnectState) => void): this; | ||
@@ -21,0 +26,0 @@ } |
@@ -1,2 +0,2 @@ | ||
import { Transform, Readable, TransformOptions } from "stream"; | ||
import { Readable, Transform, TransformOptions } from "stream"; | ||
@@ -3,0 +3,0 @@ declare class IncomingFrameStream extends Transform { |
import { EventEmitter } from "events"; | ||
import { Duplex, WritableOptions, Writable } from "stream"; | ||
import { Duplex, Writable, WritableOptions } from "stream"; | ||
@@ -4,0 +4,0 @@ import OutgoingFrameStream = require("./OutgoingFrameStream"); |
{ | ||
"name": "@types/stompit", | ||
"version": "0.26.3", | ||
"version": "0.26.4", | ||
"description": "TypeScript definitions for stompit", | ||
@@ -25,4 +25,4 @@ "homepage": "https://github.com/DefinitelyTyped/DefinitelyTyped/tree/master/types/stompit", | ||
}, | ||
"typesPublisherContentHash": "da17ec63e08f72419fcb9c136711d1c6f7db588c46d083278d56f82547814ea6", | ||
"typeScriptVersion": "3.8" | ||
"typesPublisherContentHash": "a22e032f0d6a8f458e916f76d35309e61c927092fce58faefa253e4d156e9bcf", | ||
"typeScriptVersion": "4.5" | ||
} |
@@ -11,3 +11,3 @@ # Installation | ||
### Additional Details | ||
* Last updated: Mon, 22 Nov 2021 12:01:07 GMT | ||
* Last updated: Mon, 25 Sep 2023 13:39:06 GMT | ||
* Dependencies: [@types/node](https://npmjs.com/package/@types/node) | ||
@@ -14,0 +14,0 @@ * Global values: none |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
15803
314