Skip to content

Commit fcbefd9

Browse files
committed
Small fix
1 parent e30d62c commit fcbefd9

File tree

2 files changed

+11
-7
lines changed

2 files changed

+11
-7
lines changed

src/MongoDB.Driver/IClientSession.cs

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,15 @@
2121

2222
namespace MongoDB.Driver
2323
{
24+
public static class ClientSessionExtensions
25+
{
26+
//TODO This will need to be moved somewhere else
27+
public static BsonTimestamp GetSnapshotTime(this IClientSessionHandle session)
28+
{
29+
return ((ClientSessionHandle)session).SnapshotTime;
30+
}
31+
}
32+
2433
/// <summary>
2534
/// The interface for a client session.
2635
/// </summary>
@@ -83,11 +92,6 @@ public interface IClientSession : IDisposable
8392
/// </value>
8493
IServerSession ServerSession { get; }
8594

86-
/// <summary>
87-
/// //TODO
88-
/// </summary>
89-
BsonTimestamp SnapshotTime { get; }
90-
9195
/// <summary>
9296
/// Gets the wrapped core session (intended for internal use only).
9397
/// </summary>

tests/MongoDB.Driver.Tests/AtClusterTimeTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public void AtClusterTime_should_work()
5151
var results = collection.Find(session1, filterDefinition).Sort(sortDefinition).ToList();
5252
AssertOneObj(results);
5353

54-
clusterTime1 = session1.SnapshotTime;
54+
clusterTime1 = session1.GetSnapshotTime();
5555
Assert.NotEqual(null, clusterTime1);
5656
}
5757

@@ -70,7 +70,7 @@ public void AtClusterTime_should_work()
7070
var results = collection.Find(session2, filterDefinition).Sort(sortDefinition).ToList();
7171
AssertOneObj(results);
7272

73-
var clusterTime2 = session2.SnapshotTime;
73+
var clusterTime2 = session2.GetSnapshotTime();
7474
Assert.Equal(clusterTime2, clusterTime1);
7575
}
7676

0 commit comments

Comments
 (0)