Sealing

BobLd · Sep 26, 2021 · f52374a · f52374a
1 parent 02b4aeb
commit f52374a
Show file tree

Hide file tree

Showing 14 changed files with 14 additions and 17 deletions.
diff --git a/Panoptes.Model.MongoDB/Sessions/MongoSession.cs b/Panoptes.Model.MongoDB/Sessions/MongoSession.cs
@@ -8,7 +8,7 @@
 
 namespace Panoptes.Model.MongoDB.Sessions
 {
-    public class MongoSession : BaseStreamSession
+    public sealed class MongoSession : BaseStreamSession
     {
         private readonly MongoClient _client;
         private IMongoDatabase _database;

diff --git a/Panoptes.Model.MongoDB/Sessions/MongoSessionParameters.cs b/Panoptes.Model.MongoDB/Sessions/MongoSessionParameters.cs
@@ -3,7 +3,7 @@
 
 namespace Panoptes.Model.MongoDB.Sessions
 {
-    public class MongoSessionParameters : StreamSessionParameters
+    public sealed class MongoSessionParameters : StreamSessionParameters
     {
         public string UserName { get; set; }
 

diff --git a/Panoptes.Model/Messages/AlgorithmStatusMessage.cs b/Panoptes.Model/Messages/AlgorithmStatusMessage.cs
@@ -3,7 +3,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class AlgorithmStatusMessage : ValueChangedMessage<AlgorithmStatusPacket>
+    public sealed class AlgorithmStatusMessage : ValueChangedMessage<AlgorithmStatusPacket>
     {
         public AlgorithmStatusMessage(AlgorithmStatusPacket algorithmStatus)
             : base(algorithmStatus)

diff --git a/Panoptes.Model/Messages/GridRequestMessage.cs b/Panoptes.Model/Messages/GridRequestMessage.cs
@@ -3,7 +3,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class GridRequestMessage : ValueChangedMessage<string>
+    public sealed class GridRequestMessage : ValueChangedMessage<string>
     {
         public GridRequestMessage(string key) : base(key)
         {

diff --git a/Panoptes.Model/Messages/LogEntryReceivedMessage.cs b/Panoptes.Model/Messages/LogEntryReceivedMessage.cs
@@ -3,7 +3,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class LogEntryReceivedMessage : ValueChangedMessage<object>
+    public sealed class LogEntryReceivedMessage : ValueChangedMessage<object>
     {
         public LogEntryReceivedMessage(object obj) : base(obj)
         { }

diff --git a/Panoptes.Model/Messages/OrderEventMessage.cs b/Panoptes.Model/Messages/OrderEventMessage.cs
@@ -4,7 +4,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class OrderEventMessage : ValueChangedMessage<OrderEventPacket>
+    public sealed class OrderEventMessage : ValueChangedMessage<OrderEventPacket>
     {
         public OrderEventMessage(OrderEventPacket orderEvent)
             : base(orderEvent ?? throw new ArgumentNullException(nameof(orderEvent)))

diff --git a/Panoptes.Model/Messages/SessionClosedMessage.cs b/Panoptes.Model/Messages/SessionClosedMessage.cs
@@ -2,7 +2,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class SessionClosedMessage : ValueChangedMessage<string>
+    public sealed class SessionClosedMessage : ValueChangedMessage<string>
     {
         public SessionClosedMessage() : base("Close")
         {

diff --git a/Panoptes.Model/Messages/SessionOpenedMessage.cs b/Panoptes.Model/Messages/SessionOpenedMessage.cs
@@ -2,7 +2,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class SessionOpenedMessage : ValueChangedMessage<string>
+    public sealed class SessionOpenedMessage : ValueChangedMessage<string>
     {
         public SessionOpenedMessage() : base("Open")
         {

diff --git a/Panoptes.Model/Messages/SessionStateChangedMessage.cs b/Panoptes.Model/Messages/SessionStateChangedMessage.cs
@@ -3,7 +3,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class SessionStateChangedMessage : ValueChangedMessage<SessionState>
+    public sealed class SessionStateChangedMessage : ValueChangedMessage<SessionState>
     {
         public SessionStateChangedMessage(SessionState state) : base(state)
         { }

diff --git a/Panoptes.Model/Messages/SessionUpdateMessage.cs b/Panoptes.Model/Messages/SessionUpdateMessage.cs
@@ -3,7 +3,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class SessionUpdateMessage : ValueChangedMessage<ResultContext>
+    public sealed class SessionUpdateMessage : ValueChangedMessage<ResultContext>
     {
         public SessionUpdateMessage(ResultContext resultContext)
             : base(resultContext ?? throw new ArgumentNullException(nameof(resultContext)))

diff --git a/Panoptes.Model/Messages/ShowNewSessionWindowMessage.cs b/Panoptes.Model/Messages/ShowNewSessionWindowMessage.cs
@@ -2,7 +2,7 @@
 
 namespace Panoptes.Model.Messages
 {
-    public class ShowNewSessionWindowMessage : ValueChangedMessage<string>
+    public sealed class ShowNewSessionWindowMessage : ValueChangedMessage<string>
     {
         public ShowNewSessionWindowMessage() : base("New")
         { }

diff --git a/Panoptes.Model/Sessions/File/FileSession.cs b/Panoptes.Model/Sessions/File/FileSession.cs
@@ -1,11 +1,10 @@
 using System;
 using System.IO;
 using System.Threading;
-using System.Threading.Tasks;
 
 namespace Panoptes.Model.Sessions.File
 {
-    public class FileSession : ISession, IDisposable
+    public sealed class FileSession : ISession, IDisposable
     {
         private readonly IResultSerializer _resultSerializer;
         private readonly ISessionHandler _sessionHandler;

diff --git a/Panoptes.Model/Sessions/File/FileSessionParameters.cs b/Panoptes.Model/Sessions/File/FileSessionParameters.cs
@@ -3,7 +3,7 @@
     /// <summary>
     /// Parameters used for the FileSession
     /// </summary>
-    public class FileSessionParameters : ISessionParameters
+    public sealed class FileSessionParameters : ISessionParameters
     {     /// <summary>
           /// The JSON fileName to open
           /// </summary>

diff --git a/Panoptes.Model/Sessions/Stream/StreamSession.cs b/Panoptes.Model/Sessions/Stream/StreamSession.cs
@@ -7,7 +7,7 @@
 
 namespace Panoptes.Model.Sessions.Stream
 {
-    public class StreamSession : BaseStreamSession
+    public sealed class StreamSession : BaseStreamSession
     {
         public StreamSession(ISessionHandler sessionHandler, IResultConverter resultConverter, StreamSessionParameters parameters)
            : base(sessionHandler, resultConverter, parameters)
@@ -35,8 +35,6 @@ protected override void EventsListener(object sender, DoWorkEventArgs e)
 
                         HandlePacketEventsListener(payload, packet.Type);
                     }
-
-                    pullSocket.Close();
                 }
             }
             catch (Exception)