94private BatchStreamState batchState; 118this.batchState = BatchStreamState.StartBatch; 146public BatchStreamState State 403case BatchStreamState.EndBatch: 409case BatchStreamState.Get: 410case BatchStreamState.GetResponse: 415goto case BatchStreamState.StartBatch; 417case BatchStreamState.StartBatch: 418case BatchStreamState.EndChangeSet: 421this.batchState = BatchStreamState.EndBatch; 425case BatchStreamState.BeginChangeSet: 431this.batchState = BatchStreamState.EndChangeSet; 434case BatchStreamState.ChangeResponse: 435case BatchStreamState.Delete: 438this.batchState = BatchStreamState.EndChangeSet; 441case BatchStreamState.Post: 442case BatchStreamState.Put: 443case BatchStreamState.Merge: 448this.batchState = BatchStreamState.EndChangeSet; 466this.batchState == BatchStreamState.EndBatch || 467this.batchState == BatchStreamState.EndChangeSet, 489Debug.Assert(this.batchState == BatchStreamState.EndChangeSet, "bad changeset boundary state"); 496if (BatchStreamState.EndChangeSet == this.batchState) 517Debug.Assert(this.batchState == BatchStreamState.EndChangeSet, "bad changeset boundary state"); 521if (this.batchState != BatchStreamState.EndBatch) 523if (this.batchState == BatchStreamState.EndChangeSet) 572else if (BatchStreamState.EndBatch == this.batchState) 580this.batchState = BatchStreamState.BeginChangeSet; 640if (this.batchState == BatchStreamState.BeginChangeSet) 647this.batchState == BatchStreamState.Delete || 648this.batchState == BatchStreamState.Get || 649this.batchState == BatchStreamState.Post || 650this.batchState == BatchStreamState.Put || 651this.batchState == BatchStreamState.Merge, 658if (this.batchState == BatchStreamState.EndBatch) 663if (this.batchState != BatchStreamState.BeginChangeSet) 672this.batchState == BatchStreamState.BeginChangeSet || 673(this.batchRequest && (this.batchState == BatchStreamState.Delete || 674this.batchState == BatchStreamState.Get || 675this.batchState == BatchStreamState.Post || 676this.batchState == BatchStreamState.Put || 677this.batchState == BatchStreamState.Merge)) || 678(!this.batchRequest && (this.batchState == BatchStreamState.GetResponse || 679this.batchState == BatchStreamState.ChangeResponse)), 687case BatchStreamState.BeginChangeSet: 688case BatchStreamState.Delete: 689case BatchStreamState.Get: 690case BatchStreamState.ChangeResponse: // example DELETE /Customers(1) 691case BatchStreamState.GetResponse: // example GET /Customers(1)/BestFriend 694case BatchStreamState.Post: 695case BatchStreamState.Put: 696case BatchStreamState.Merge: 709case BatchStreamState.BeginChangeSet: 710case BatchStreamState.Post: 711case BatchStreamState.Put: 712case BatchStreamState.Merge: 713case BatchStreamState.GetResponse: 714case BatchStreamState.ChangeResponse: 718case BatchStreamState.Get: // request does not expect content-type 719case BatchStreamState.Delete: // request does not expect content-type 778private static BatchStreamState GetStateBasedOnHttpMethodName(string methodName) 782return BatchStreamState.Get; 786return BatchStreamState.Delete; 790return BatchStreamState.Post; 794return BatchStreamState.Put; 798return BatchStreamState.Merge; 1382BatchStreamState state; 1393state = (BatchStreamState.EndBatch == this.batchState) ? BatchStreamState.GetResponse : BatchStreamState.ChangeResponse; 1401BatchStreamState.EndBatch == this.batchState || 1402BatchStreamState.EndChangeSet == this.batchState, 1405if (this.batchState == BatchStreamState.EndBatch) 1407if ((this.batchRequest && (state == BatchStreamState.Get)) || 1408(!this.batchRequest && (state == BatchStreamState.GetResponse))) 1417else if (this.batchState == BatchStreamState.EndChangeSet) 1419if ((this.batchRequest && ((BatchStreamState.Post == state) || (BatchStreamState.Put == state) || (BatchStreamState.Delete == state) || (BatchStreamState.Merge == state))) || 1420(!this.batchRequest && (state == BatchStreamState.ChangeResponse))) 1428this.batchState = BatchStreamState.Post;

349private static string GetHttpMethodName(BatchStreamState state) 352state == BatchStreamState.Get || 353state == BatchStreamState.Post || 354state == BatchStreamState.Put || 355state == BatchStreamState.Delete || 356state == BatchStreamState.Merge, 361case BatchStreamState.Delete: 363case BatchStreamState.Get: 365case BatchStreamState.Post: 367case BatchStreamState.Merge: 370Debug.Assert(BatchStreamState.Put == state, "BatchStreamState.Put == state");

2362while (!this.batchLimitExceeded && this.batchRequestStream.State != BatchStreamState.EndBatch) 2389case BatchStreamState.BeginChangeSet: 2399case BatchStreamState.EndChangeSet: 2451case BatchStreamState.Get: 2473case BatchStreamState.Post: 2474case BatchStreamState.Put: 2475case BatchStreamState.Delete: 2476case BatchStreamState.Merge: 2499if (this.batchRequestStream.State == BatchStreamState.Post) 2512else if (this.batchRequestStream.State == BatchStreamState.Put) 2526Debug.Assert(this.batchRequestStream.State == BatchStreamState.EndBatch, "expecting end batch state"); 2544if (this.batchRequestStream.State == BatchStreamState.EndChangeSet) 2548else if (this.batchRequestStream.State == BatchStreamState.Post || 2549this.batchRequestStream.State == BatchStreamState.Put || 2550this.batchRequestStream.State == BatchStreamState.Delete || 2551this.batchRequestStream.State == BatchStreamState.Merge) 2573if (this.batchRequestStream.State == BatchStreamState.EndChangeSet) 2723Debug.Assert(this.batchRequestStream.State == BatchStreamState.Put, "This method must be called only for PUT requests");

40internal static DataServiceException BatchStreamContentExpected(BatchStreamState state) 48internal static DataServiceException BatchStreamContentUnexpected(BatchStreamState state)