mirror of
https://github.com/go-i2p/go-sam-go.git
synced 2025-12-01 09:54:58 -05:00
Rename test session identifiers to include 'stream_' prefix for clarity and consistency
This commit is contained in:
@@ -19,7 +19,7 @@ func TestStreamSession_Dial(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_dial", keys, []string{
|
session, err := NewStreamSession(sam, "stream_test_dial", keys, []string{
|
||||||
"inbound.length=1", "outbound.length=1",
|
"inbound.length=1", "outbound.length=1",
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -98,7 +98,7 @@ func TestStreamSession_DialI2P(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_dial_i2p", keys, []string{
|
session, err := NewStreamSession(sam, "stream_test_dial_i2p", keys, []string{
|
||||||
"inbound.length=1", "outbound.length=1",
|
"inbound.length=1", "outbound.length=1",
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -177,7 +177,7 @@ func TestStreamSession_DialContext(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_dial_context", keys, nil)
|
session, err := NewStreamSession(sam, "stream_test_dial_context", keys, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to create session: %v", err)
|
t.Fatalf("Failed to create session: %v", err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ func TestSessionListenerLifecycle(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_lifecycle", keys, nil)
|
session, err := NewStreamSession(sam, "stream_test_lifecycle", keys, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to create session: %v", err)
|
t.Fatalf("Failed to create session: %v", err)
|
||||||
}
|
}
|
||||||
@@ -70,7 +70,7 @@ func TestExplicitListenerClose(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_explicit_close", keys, nil)
|
session, err := NewStreamSession(sam, "stream_test_explicit_close", keys, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to create session: %v", err)
|
t.Fatalf("Failed to create session: %v", err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ func TestStreamSession_Listen(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_listen", keys, []string{
|
session, err := NewStreamSession(sam, "stream_test_listen", keys, []string{
|
||||||
"inbound.length=1", "outbound.length=1",
|
"inbound.length=1", "outbound.length=1",
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -41,7 +41,7 @@ func TestStreamSession_NewDialer(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_dialer", keys, nil)
|
session, err := NewStreamSession(sam, "stream_test_dialer", keys, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to create session: %v", err)
|
t.Fatalf("Failed to create session: %v", err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -99,7 +99,7 @@ func TestStreamSession_Close(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_close", keys, nil)
|
session, err := NewStreamSession(sam, "stream_test_close", keys, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to create session: %v", err)
|
t.Fatalf("Failed to create session: %v", err)
|
||||||
}
|
}
|
||||||
@@ -127,7 +127,7 @@ func TestStreamSession_Addr(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_addr", keys, nil)
|
session, err := NewStreamSession(sam, "stream_test_addr", keys, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to create session: %v", err)
|
t.Fatalf("Failed to create session: %v", err)
|
||||||
}
|
}
|
||||||
@@ -145,7 +145,7 @@ func TestStreamSession_ConcurrentOperations(t *testing.T) {
|
|||||||
sam, keys := setupTestSAM(t)
|
sam, keys := setupTestSAM(t)
|
||||||
defer sam.Close()
|
defer sam.Close()
|
||||||
|
|
||||||
session, err := NewStreamSession(sam, "test_concurrent", keys, nil)
|
session, err := NewStreamSession(sam, "stream_test_concurrent", keys, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to create session: %v", err)
|
t.Fatalf("Failed to create session: %v", err)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user